package com.oss.mq.mapper;

import com.oss.mq.entity.pojo.TaskQueue;

public interface TaskQueueMapper {
    int deleteByPrimaryKey(Long taskQueueId);

    int insertSelective(TaskQueue record);

    TaskQueue selectByPrimaryKey(Long taskQueueId);

    TaskQueue selectNextTask();

    TaskQueue selectByServiceId(Long serviceId,String taskState);

    int updateByPrimaryKeySelective(TaskQueue record);

}